Crate send_wrapper
source · [−]Expand description
This Rust library implements a wrapper type called SendWrapper
which allows you to move around non-Send
types
between threads, as long as you access the contained value only from within the original thread. You also have to
make sure that the wrapper is dropped from within the original thread. If any of these constraints is violated,
a panic occurs. SendWrapper<T>
implements Send
and Sync
for any type T
.
The idea for this library was born in the context of a GTK+
/gtk-rs
-based application. GTK+
applications
are strictly single-threaded. It is not allowed to call any GTK+
method from a thread different to the main
thread. Consequently, all gtk-rs
structs are non-Send
.
Sometimes you still want to do some work in background. It is possible to enqueue GTK+
calls from there to be
executed in the main thread using Glib
. This way you can know, that the gtk-rs
structs involved are only
accessed in the main thread and will also be dropped there. This library makes it possible that gtk-rs
structs
can leave the main thread at all.
Examples
use send_wrapper::SendWrapper;
use std::rc::Rc;
use std::thread;
use std::sync::mpsc::channel;
// This import is important if you want to use deref() or
// deref_mut() instead of Deref coercion.
use std::ops::{Deref, DerefMut};
// Rc is a non-Send type.
let value = Rc::new(42);
// We now wrap the value with `SendWrapper` (value is moved inside).
let wrapped_value = SendWrapper::new(value);
// A channel allows us to move the wrapped value between threads.
let (sender, receiver) = channel();
let t = thread::spawn(move || {
// This would panic (because of dereferencing in wrong thread):
// let value = wrapped_value.deref();
// Move SendWrapper back to main thread, so it can be dropped from there.
// If you leave this out the thread will panic because of dropping from wrong thread.
sender.send(wrapped_value).unwrap();
});
let wrapped_value = receiver.recv().unwrap();
// Now you can use the value again.
let value = wrapped_value.deref();
// alternatives for dereferencing:
let value = &*wrapped_value;
let value: &Rc<_> = &wrapped_value;
let mut wrapped_value = wrapped_value;
// alternatives for mutable dereferencing:
let value = wrapped_value.deref_mut();
let value = &mut *wrapped_value;
let value: &mut Rc<_> = &mut wrapped_value;
Features
This crate has a single feature called futures
that enables Future
and Stream
implementations for SendWrapper
.
You can enable it in Cargo.toml
like so:
send_wrapper = { version = "...", features = ["futures"] }
License
send_wrapper
is distributed under the terms of both the MIT license and the Apache License (Version 2.0).
See LICENSE-APACHE.txt, and LICENSE-MIT.txt for details.
Structs
A wrapper which allows you to move around non-Send
-types between threads, as long as you access the contained
value only from within the original thread and make sure that it is dropped from within the original thread.